package com.codejiwei.flink.transform;

import org.apache.flink.api.common.functions.MapFunction;

/**
 * @author jiwei
 * @description
 * @date 2023/5/19 16:34
 */
public class MapMultiply implements MapFunction<Integer, Integer> {

    @Override
    public Integer map(Integer integer) throws Exception {
        return integer * integer;
    }
}
